package cn.me.alphamq.broker.event.model.broker;

import cn.me.alphamq.common.entity.req.PushDelayMsgReq;
import cn.me.alphamq.common.event.model.Event;

/**
 * 生产者生产延迟消息的事件
 *
 * @author f
 */
public class PushDelayMsgEvent extends Event {

    private final PushDelayMsgReq pushDelayMsgReq;

    public PushDelayMsgEvent(PushDelayMsgReq pushDelayMsgReq) {
        super(pushDelayMsgReq.getMsgId());
        this.pushDelayMsgReq = pushDelayMsgReq;
    }

    public PushDelayMsgReq getDelayMsgReq() {
        return pushDelayMsgReq;
    }
}
